package com.norma.netty.study.netty.disruptor;

import com.norma.netty.study.netty.disruptor.core.MessageConsumer;

/**
 * @author zhangchaofeng
 * @date 2021/1/6
 * @description
 */
public class MessageConsumerImpl4Client extends MessageConsumer {

    public MessageConsumerImpl4Client(String consumerId) {
        super(consumerId);
    }

    @Override
    public void onEvent(TransDataWrapper event) throws Exception {
        System.out.println(consumerId + "-->" + event.toString());
    }
}
